package com.sh.data.engine.domain.datadev.flink.model.param;

import lombok.Data;

import java.util.List;

/**
 * @author : fuchen
 * @date : 2021/6/15 11:37
 */
@Data
public class SaveCollectionTaskParam {

    private Long id;

    private Long nodeId;

    private Long projectId;

    private Long userId;

    private Integer sourceDsId;

    private String sourceDsType;

    private String sourceTopic;

    /**
     * 任务类型:0-Binlog 1-间隔轮训: 2-LogMiner<br>
     * 用在读取源表上,要是源表是kafka该值是null
     */
    private Integer taskType;

    private List<String> sourceTable;

    private List<Integer> operatorMode;

    private Integer start;

    private String startValue;

    private String schema;

    private Boolean pavingData;

    private String increColumn;

    private String startLocation;

    private Integer pollingInterval;

    /**
     * mysql源选了间隔轮询会用到
     */
    private List<String> columns;

    private Integer targetDsId;

    private String targetDsType;

    private String targetTopic;

    private Integer targetTableExiting;

    private String targetTableName;

    /**
     * 是否是富文本 0-否 1-有
     */
    private Integer isSupportText;

    private String targetDatabase;

    private Integer partitionType;

    private Integer writeMode;

    private String writeModeRdbms;

    private Integer interval;

    private String partition;

    // ------------flinkx老模式的参数全部使用上边的散在外边的 flinksql模式的使用下边的封装的------------------------------//
  /*private TableConfigDomain tableConfigSource;

  private TableConfigDomain tableConfigSink;

  */
    /** 目前也只能是用在源表是cdc的了 */
  /*
  private TableMapping tableMapping;*/
}
